Micron Document
πŸŽ–οΈGitΠ―Ρ€Π°πŸŽ–οΈ

Node / meshtastic / Meshtastic-Android / files / core / takserver / src / commonTest / kotlin / org / meshtastic / core / takserver / TAKServerManagerTest.kt

Displaying Raw β€’ Download

core/takserver/src/commonTest/kotlin/org/meshtastic/core/takserver/TAKServerManagerTest.kt 65a1f5ce4d0e4b8eafcd0bbfccafd41dc6ee888a (65a1f5ce) Text, 10.68 KB

T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.takserver

Tff7b72import T7ee787kotlinx.coroutines.CompletableDeferred
Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.flow.StateFlow
Tff7b72import T7ee787kotlinx.coroutines.test.advanceUntilIdle
Tff7b72import T7ee787kotlinx.coroutines.test.runCurrent
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals
Tff7b72import T7ee787kotlin.test.assertTrue
Tff7b72import T7ee787kotlin.time.Clock
Tff7b72import T7ee787kotlin.time.Duration.Companion.minutes

T8b949e/**
* Tests for [TAKServerManagerImpl] offline message queue behavior:
* - FIFO eviction at 50-message cap (T074)
* - Per-message TTL expiry after 5 minutes (T074)
* - Replay of queued messages on client reconnect (T074)
*/
Tff7b72class T56d364TAKServerManagerTest Tb4b4b4{

T8b949e/** Fake TAKServer that records broadcasts and simulates connection state. */
Tff7b72private Tff7b72class T56d364FakeTAKServer Tb4b4b4: Te6edf3TAKServer Tb4b4b4{
Tff7b72override Tff7b72val Te6edf3connectionCountTb4b4b4: Te6edf3StateFlowTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3MutableStateFlowTb4b4b4(T79c0ff0Tb4b4b4)
Tff7b72override Tff7b72var Te6edf3onMessageTb4b4b4: Tb4b4b4(Tb4b4b4(Te6edf3CoTMessageTb4b4b4, Te6edf3TAKClientInfo?Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null
Tff7b72override Tff7b72var Te6edf3onClientConnectedTb4b4b4: Tb4b4b4(Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null

Tff7b72var Te6edf3stubHasConnections Tff7b72= Tff7b72false
Tff7b72val Te6edf3broadcasts Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3CoTMessageTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3rawBroadcasts Tff7b72= Te6edf3mutableListOfTff7b72<Tffa657StringTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstartTb4b4b4(Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72= Te6edf3ResultTb4b4b4.Te6edf3successTb4b4b4(Tffa657UnitTb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffstopTb4b4b4(Tb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastTb4b4b4(Te6edf3cotMessageTb4b4b4: Te6edf3CoTMessageTb4b4b4) Tb4b4b4{
Te6edf3broadcastsTb4b4b4.Te6edf3addTb4b4b4(Te6edf3cotMessageTb4b4b4)
Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastRawXmlTb4b4b4(Te6edf3xmlTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{
Te6edf3rawBroadcastsTb4b4b4.Te6edf3addTb4b4b4(Te6edf3xmlTb4b4b4)
Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffhasConnectionsTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Te6edf3stubHasConnections
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffcreatePliTb4b4b4(Te6edf3uidTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3CoTMessage Tb4b4b4{
Tff7b72val Te6edf3now Tff7b72= Te6edf3ClockTb4b4b4.Te6edf3SystemTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4)
Tff7b72return Te6edf3CoTMessageTb4b4b4(
Te6edf3uid Tff7b72= Te6edf3uidTb4b4b4,
Te6edf3type Tff7b72= Te6edf3DEFAULT_PLI_COT_TYPETb4b4b4,
Te6edf3stale Tff7b72= Te6edf3now Tff7b72+ T79c0ff5.Te6edf3minutesTb4b4b4,
Te6edf3latitude Tff7b72= T79c0ff4T79c0ff5.0Tb4b4b4,
Te6edf3longitude Tff7b72= Tff7b72-T79c0ff9T79c0ff0.0Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`offline queue caps at 50 messages with FIFO eviction`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72false
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Queue 55 messages (5 more than the cap)
Te6edf3repeatTb4b4b4(T79c0ff5T79c0ff5Tb4b4b4) Tb4b4b4{ Te6edf3i Tff7b72-Tff7b72> Te6edf3managerTb4b4b4.Te6edf3broadcastTb4b4b4(Te6edf3createPliTb4b4b4(Ta5d6ff"Ta5d6ffuid-Tffd700$Te6edf3iTa5d6ff"Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Now simulate a client connecting β€” drain the queue
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72true
Te6edf3managerTb4b4b4.Te6edf3drainOfflineQueueTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Should have drained exactly 50 messages (the oldest 5 evicted by FIFO)
Te6edf3assertEqualsTb4b4b4(T79c0ff5T79c0ff0Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3sizeTb4b4b4)
T8b949e// The first message drained should be uid-5 (uid-0 through uid-4 were evicted)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffuid-5Ta5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3uidTb4b4b4)
T8b949e// The last message drained should be uid-54
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffuid-54Ta5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3lastTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3uidTb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`offline queue expires messages after 5 minute TTL`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72false
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Queue 3 messages β€” these will be stamped with Clock.System.now()
Te6edf3repeatTb4b4b4(T79c0ff3Tb4b4b4) Tb4b4b4{ Te6edf3i Tff7b72-Tff7b72> Te6edf3managerTb4b4b4.Te6edf3broadcastTb4b4b4(Te6edf3createPliTb4b4b4(Ta5d6ff"Ta5d6ffmsg-Tffd700$Te6edf3iTa5d6ff"Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Immediately drain (no time has passed) β€” all messages should still be valid
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72true
Te6edf3managerTb4b4b4.Te6edf3drainOfflineQueueTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// All 3 messages should be delivered (none expired yet since <5 min elapsed)
Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3sizeTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmsg-0Ta5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3uidTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmsg-1Ta5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3uidTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmsg-2Ta5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTff7b72[T79c0ff2Tff7b72]Tb4b4b4.Te6edf3uidTb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`offline queue replays messages in order on client reconnect`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72false
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Queue messages in order
Tff7b72val Te6edf3uids Tff7b72= Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffalphaTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffbravoTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffcharlieTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffdeltaTa5d6ff"Tb4b4b4)
Te6edf3uidsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3uid Tff7b72-Tff7b72> Te6edf3managerTb4b4b4.Te6edf3broadcastTb4b4b4(Te6edf3createPliTb4b4b4(Te6edf3uidTb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Simulate client reconnect
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72true
Te6edf3managerTb4b4b4.Te6edf3drainOfflineQueueTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Messages should be replayed in FIFO order
Te6edf3assertEqualsTb4b4b4(Te6edf3uidsTb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3uid Tb4b4b4}Tb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`broadcast goes directly to TAK server when clients connected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72true
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3broadcastTb4b4b4(Te6edf3createPliTb4b4b4(Ta5d6ff"Ta5d6ffdirectTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Message should be broadcast directly, not queued
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3sizeTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffdirectTa5d6ff"Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3broadcastsTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3uidTb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)
Tb4b4b4}

T8b949e// ── T076: Port conflict / start failure ─────────────────────────────────────

T8b949e/** Fake TAKServer that simulates a port-conflict failure on start. */
Tff7b72private Tff7b72class T56d364FailingTAKServer Tb4b4b4: Te6edf3TAKServer Tb4b4b4{
Tff7b72override Tff7b72val Te6edf3connectionCountTb4b4b4: Te6edf3StateFlowTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3MutableStateFlowTb4b4b4(T79c0ff0Tb4b4b4)
Tff7b72override Tff7b72var Te6edf3onMessageTb4b4b4: Tb4b4b4(Tb4b4b4(Te6edf3CoTMessageTb4b4b4, Te6edf3TAKClientInfo?Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null
Tff7b72override Tff7b72var Te6edf3onClientConnectedTb4b4b4: Tb4b4b4(Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstartTb4b4b4(Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72=
Te6edf3ResultTb4b4b4.Te6edf3failureTb4b4b4(Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6ffAddress already in use: port 8089Ta5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffstopTb4b4b4(Tb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastTb4b4b4(Te6edf3cotMessageTb4b4b4: Te6edf3CoTMessageTb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastRawXmlTb4b4b4(Te6edf3xmlTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffhasConnectionsTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false
Tb4b4b4}

Tff7b72private Tff7b72class T56d364DelayedTAKServer Tb4b4b4: Te6edf3TAKServer Tb4b4b4{
Tff7b72override Tff7b72val Te6edf3connectionCountTb4b4b4: Te6edf3StateFlowTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3MutableStateFlowTb4b4b4(T79c0ff0Tb4b4b4)
Tff7b72override Tff7b72var Te6edf3onMessageTb4b4b4: Tb4b4b4(Tb4b4b4(Te6edf3CoTMessageTb4b4b4, Te6edf3TAKClientInfo?Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null
Tff7b72override Tff7b72var Te6edf3onClientConnectedTb4b4b4: Tb4b4b4(Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tff7b72? Tff7b72= Tff7b72null

Tff7b72val Te6edf3startResults Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3CompletableDeferredTff7b72<Te6edf3ResultTff7b72<Tffa657UnitTff7b72>Tff7b72>Tff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72var Te6edf3stopCount Tff7b72= T79c0ff0

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstartTb4b4b4(Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72=
Te6edf3CompletableDeferredTff7b72<Te6edf3ResultTff7b72<Tffa657UnitTff7b72>Tff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3alsoTb4b4b4(Te6edf3startResultsTff7b72::Te6edf3addTb4b4b4)Tb4b4b4.Te6edf3awaitTb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffstopTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3stopCountTff7b72+Tff7b72+
Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastTb4b4b4(Te6edf3cotMessageTb4b4b4: Te6edf3CoTMessageTb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffbroadcastRawXmlTb4b4b4(Te6edf3xmlTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffhasConnectionsTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`start failure due to port conflict reports an error state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3failingServer Tff7b72= Te6edf3FailingTAKServerTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3failingServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Tff7b72falseTb4b4b4, Te6edf3managerTb4b4b4.Te6edf3isRunningTb4b4b4.Te6edf3valueTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3managerTb4b4b4.Te6edf3hasStartErrorTb4b4b4.Te6edf3valueTb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`next start waits for stale start cleanup`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3delayedServer Tff7b72= Te6edf3DelayedTAKServerTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3delayedServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3delayedServerTb4b4b4.Te6edf3startResultsTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3managerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3delayedServerTb4b4b4.Te6edf3startResultsTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3delayedServerTb4b4b4.Te6edf3startResultsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3completeTb4b4b4(Te6edf3ResultTb4b4b4.Te6edf3successTb4b4b4(Tffa657UnitTb4b4b4)Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3delayedServerTb4b4b4.Te6edf3startResultsTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3delayedServerTb4b4b4.Te6edf3startResultsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3completeTb4b4b4(Te6edf3ResultTb4b4b4.Te6edf3successTb4b4b4(Tffa657UnitTb4b4b4)Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3managerTb4b4b4.Te6edf3isRunningTb4b4b4.Te6edf3valueTb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3delayedServerTb4b4b4.Te6edf3stopCountTb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`start failure clears onMessage callback`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3failingServer Tff7b72= Te6edf3FailingTAKServerTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3failingServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// onMessage should be cleared after failed start
Te6edf3assertEqualsTb4b4b4(Tff7b72nullTb4b4b4, Te6edf3failingServerTb4b4b4.Te6edf3onMessageTb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`broadcast is no-op after failed start`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3failingServer Tff7b72= Te6edf3FailingTAKServerTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3failingServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Broadcast should silently do nothing (not crash)
Te6edf3managerTb4b4b4.Te6edf3broadcastTb4b4b4(Te6edf3createPliTb4b4b4(Ta5d6ff"Ta5d6ffshould-be-droppedTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No exception = pass. isRunning is false so broadcast exits early.
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`broadcastRawXml forwards to TAKServer when running`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Te6edf3fakeTakServerTb4b4b4.Te6edf3stubHasConnections Tff7b72= Tff7b72true
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3startTb4b4b4(Tff7b72thisTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3rawXml Tff7b72= Ta5d6ff"""Ta5d6ff<event type=Ta5d6ff"Ta5d6ffa-f-GTa5d6ff"Ta5d6ff uid=Ta5d6ff"Ta5d6fftestTa5d6ff"Ta5d6ff/>Ta5d6ff"""
Te6edf3managerTb4b4b4.Te6edf3broadcastRawXmlTb4b4b4(Te6edf3rawXmlTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3rawBroadcastsTb4b4b4.Te6edf3sizeTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3rawXmlTb4b4b4, Te6edf3fakeTakServerTb4b4b4.Te6edf3rawBroadcastsTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`broadcastRawXml is no-op when not running`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fakeTakServer Tff7b72= Te6edf3FakeTAKServerTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3manager Tff7b72= Te6edf3TAKServerManagerImplTb4b4b4(Te6edf3fakeTakServerTb4b4b4)
T8b949e// Don't call start()

Te6edf3managerTb4b4b4.Te6edf3broadcastRawXmlTb4b4b4(Ta5d6ff"""Ta5d6ff<event type=Ta5d6ff"Ta5d6ffa-f-GTa5d6ff"Ta5d6ff/>Ta5d6ff"""Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3fakeTakServerTb4b4b4.Te6edf3rawBroadcastsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tb4b4b4}

Served by rngit 1.5.0 - Generated in 0.09s